package com.itheima.juc18.blockingqueue;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @author li
 * 需求：利用阻塞队列来实现生产者和消费者（等待唤醒机制）的代码
 * 细节：生产者和消费者必须使用同一个阻塞队列
 */
public class ThreadDemo {
    public static void main(String[] args) {
        // 1.创建阻塞队列的对象
        ArrayBlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(1);
        // 2.创建线程对象，并把队列传递过去
        Producer producer = new Producer(blockingQueue);
        Consumer consumer = new Consumer(blockingQueue);
        // 3.开启线程
        producer.start();
        consumer.start();
    }
}
